package com.opensky.module.sys.interfaces.assembler;

import com.opensky.module.sys.domain.jpa.entity.SysDept;
import com.opensky.module.sys.interfaces.frm.SysDeptSaveFrm;
import com.opensky.module.sys.interfaces.frm.SysDeptQueryFrm;
import com.opensky.module.sys.interfaces.vo.SysDeptVO;
import com.opensky.module.sys.interfaces.validator.SysDeptValidator;
import com.opensky.common.infrastructure.util.DataBeanUtil;
import com.opensky.common.interfaces.frm.CommonIdFrm;
import com.opensky.common.interfaces.frm.CommonIdsFrm;
import com.opensky.common.interfaces.vo.PageVO;

import org.springframework.data.domain.Sort;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.PageImpl;
import org.springframework.data.jpa.domain.Specification;
import org.springframework.util.CollectionUtils;
import org.springframework.stereotype.Component;

import java.util.ArrayList;
import java.util.List;
import java.util.Date;

/**
 * 部门表(表sys_dept)数据转换辅助对象
 *
 * @author 🇨🇳中国印🇨🇳
 * @date 2021年11月28日
 */
@Component
public class SysDeptAssembler {

    /**
     * 新增数据
     *
     * @param frm 待新增的frm对象
     * @return 成功返回新增后的VO对象，失败返回null
     */
    public SysDeptVO insert(SysDeptSaveFrm frm) {
        SysDept entity = convertFromFrm(frm);
        entity.setCreateTime(new Date());
        entity.setUpdateTime(new Date());
        return convertToVO(entity.save());
    }

    /**
     * 删除数据
     *
     * @param frm 主键frm对象
     */
    public Integer delete(CommonIdFrm frm) {
        SysDept entity = SysDept.builder().id(frm.getId()).build();
        entity.remove();
        return 1;
    }

    /**
     * 更新数据
     *
     * @param frm 待更新的frm对象
     * @return 成功返回更新后的VO对象，失败返回null
     */
    public SysDeptVO update(SysDeptSaveFrm frm) {
        SysDept entity = convertFromFrm(frm);
        entity.setUpdateTime(new Date());
        return convertToVO(entity.updateSelective());
    }

    /**
     * 通过主键查询单条数据
     *
     * @param frm 主键Frm对象
     * @return 成功返回对应ID的VO对象，失败返回null
     */
    public SysDeptVO findById(CommonIdFrm frm) {
        SysDept entity = SysDept.builder().id(frm.getId()).build();
        return convertToVO(entity.findById());
    }

    /**
     * 通过主键批量查询数据集合
     *
     * @param frm 主键集合Frm对象
     * @return 成功返回对应ID的VO对象，失败返回空集合
     */
    public List<SysDeptVO> findByIds(CommonIdsFrm frm) {
        List<SysDeptVO> retList = new ArrayList<>();
        List<SysDept> list = SysDept.builder().build().findByIds(frm.getIds());
        if (!CollectionUtils.isEmpty(list)) {
            list.forEach(x -> retList.add(convertToVO(x)));
        }
        return retList;
    }

    /**
     * 根据条件获取数据集
     *
     * @param frm 查询条件对象
     * @return 成功返回满足条件的数据集合，失败返回空集合
     */
    public List<SysDeptVO> getList(SysDeptQueryFrm frm) {
        List<SysDeptVO> retList = new ArrayList<>();
        // 转换查询条件
        Specification<SysDept> specification = SysDept.getSpecification(frm);
        // 转换排序条件
        Sort sort = SysDept.getSort(frm.getSortFields());
        SysDept entity = SysDept.builder().build();
        // 查询集合
        List<SysDept> list = entity.findAll(specification, sort);
        // 转换成VO
        if (!CollectionUtils.isEmpty(list)) {
            list.forEach(x -> retList.add(convertToVO(x)));
        }
        return retList;
    }

    /**
     * 根据条件查询数据分页
     *
     * @param frm 查询条件参数
     * @return 成功返回满足条件的分页，失败返回空页
     */
    public PageVO<SysDeptVO> getPageInfo(SysDeptQueryFrm frm) {
        // 转换查询条件
        Specification<SysDept> specification = SysDept.getSpecification(frm);
        // 转换排序条件
        Sort sort = SysDept.getSort(frm.getSortFields());
        SysDept entity = SysDept.builder().build();
        // 查询分页
        Page<SysDept> page = entity.findAll(specification, frm.getPageNum(), frm.getPageSize(), sort);
        Page<SysDeptVO> retPage = new PageImpl<>(new ArrayList<>(), page.getPageable(), page.getTotalElements());
        // 转换成VO
        if (page.hasContent()) {
            List<SysDeptVO> voList = new ArrayList<>();
            page.getContent().forEach(x -> voList.add(convertToVO(x)));
            retPage = new PageImpl<>(voList, page.getPageable(), page.getTotalElements());
        }
        return new PageVO<>(retPage);
    }

    /**
     * 实体类转VO
     *
     * @param entity 实体类
     * @return 转换后的对象
     */
    public SysDeptVO convertToVO(SysDept entity) {
        return entity == null ? null : DataBeanUtil.copyOf(entity, SysDeptVO.class, true);
    }

    /**
     * Frm转实体类
     *
     * @param frm 参数对象
     * @return 转换后的实体类对象
     */
    public SysDept convertFromFrm(SysDeptSaveFrm frm) {
        SysDeptValidator.validateFrm(this, frm);
        return DataBeanUtil.copyOf(frm, SysDept.class, true);
    }
}

